package com.datalinkx.driver.dsdriver;


import com.datalinkx.driver.dsdriver.base.model.FlinkActionMeta;

/**
 * 写入的数据源驱动抽象
 */
public interface IDsWriter extends IDsDriver {
    // ============= Flinkx 引擎
    // 清空数据，用于全量同步，暂时不用
    void truncateData(FlinkActionMeta param) throws Exception;

    /**
     * // 获取jobGraph writer信息
     * @param param
     * @return
     * @throws Exception
     */
    Object getWriterInfo(FlinkActionMeta param) throws Exception;

   /* // ============= Seatunnel引擎
    // 构造seatunnel引擎写信息
    default TransformNode getSinkInfo(SeatunnelActionMeta param) {
        return null;
    }
    // 构造seatunnel引擎sink中sql
    default String transferSinkSQL(SeatunnelActionMeta param) {
        return "";
    }*/
}
